package com.cti.commons.delayqueue.core;

import com.cti.commons.delayqueue.config.DelayQueueConfig;

/**
 * @author et.wang
 * @description: 常量定义
 * @date 2022/10/27 19:37
 */
public class DelayQueueConstant {

    /**
     * 延时桶
     */
    public static final String DELAY_BUCKET_KEY_PREFIX = DelayQueueConfig.getBucketJobName();

    /**
     * 延时桶的数量
     */
    public static final int DELAY_BUCKET_NUM = DelayQueueConfig.getBucketSize();

    /**
     * 延时任务池
     */
    public static final String DELAY_QUEUE_JOB_POOL = DelayQueueConfig.getQueueJobName();

}
